package com.starrtc.demo.imclient.kcp.usmp;


import java.util.concurrent.PriorityBlockingQueue;

public class MessageQueue<T> {
	private PriorityBlockingQueue<T> queue = new PriorityBlockingQueue<T>();
	private static class SinglonHolder {
		 @SuppressWarnings("rawtypes")
        final static  MessageQueue<?> holder = new MessageQueue();
	}
	public static MessageQueue<?> getInstance(){
		return SinglonHolder.holder;
	}
	public void push(T usmpFrame) {
//        log.info("push"+usmpFrame.toString());
		queue.put(usmpFrame);
	}

}
